package com.atguigu.java8;

import java.util.Arrays;
import java.util.List;
import java.util.Optional;
import java.util.stream.Stream;

import org.junit.Test;

import com.atguigu.java8.Employee.Status;

/*
 * 一、 Stream 的操作步骤
 * 
 * 1. 创建 Stream
 * 
 * 2. 中间操作
 *
					* 3. 终止操作
					*/
	public class TestStreamAPI2_终止操作查找与匹配_noneMatch {

		List<Employee> emps = Arrays.asList(
				new Employee(102, "李四", 59, 6666.66, Status.BUSY),
				new Employee(101, "张三", 18, 9999.99, Status.FREE),
				new Employee(103, "王五", 28, 3333.33, Status.VOCATION),
				new Employee(104, "赵六", 8, 7777.77, Status.BUSY),
				new Employee(104, "赵六", 8, 7777.77, Status.FREE),
				new Employee(104, "赵六", 8, 7777.77, Status.FREE),
			new Employee(105, "田七", 38, 5555.55, Status.BUSY)
	);
	
	//3. 终止操作
	/*
		allMatch——检查是否匹配所有元素
		anyMatch——检查是否至少匹配一个元素
		noneMatch——检查是否没有匹配的元素
		findFirst——返回第一个元素
		findAny——返回当前流中的任意元素
		count——返回流中元素的总个数
		max——返回流中最大值
		min——返回流中最小值
	 */
	@Test
	public void test1(){
		//		allMatch——检查是否匹配所有元素
			boolean bl = emps.stream()
				.allMatch((e) -> e.getStatus().equals(Status.BUSY));
			System.out.println(bl);


			//		anyMatch——检查是否至少匹配一个元素
			boolean bl1 = emps.stream()
				.anyMatch((e) -> e.getStatus().equals(Status.BUSY));
			System.out.println(bl1);


//				noneMatch——检查是否没有匹配的元素
		// noneMatch 没有匹配的  返回true
		//应该叫：流里是不是没有元素能够匹配指定的规则
			boolean bl2 = emps.stream()
				.noneMatch((e) -> e.getStatus().equals(Status.BUSY));
			System.out.println(bl2);
	}
	
	@Test
	public void test2(){
		Optional<Employee> op = emps.stream()
			.sorted((e1, e2) -> Double.compare(e1.getSalary(), e2.getSalary()))
				//		findFirst——返回第一个元素
			.findFirst();
		
		System.out.println(op.get());
		
		System.out.println("--------------------------------");
		
		Optional<Employee> op2 = emps.parallelStream()
			.filter((e) -> e.getStatus().equals(Status.FREE))
				//		findAny——返回当前流中的任意元素
			.findAny();
		
		System.out.println(op2.get());
	}
	
	@Test
	public void test3(){
		long count = emps.stream()
						 .filter((e) -> e.getStatus().equals(Status.FREE))
				//		count——返回流中元素的总个数
						 .count();
		System.out.println(count);


		Optional<Double> op = emps.stream()
				//map,获取、转化
				//		map——接收 Lambda ， 将元素转换成其他形式或提取信息。接收一个函数作为参数，该函数会被应用到每个元素上，并将其映射成一个新的元素。
			.map(Employee::getSalary)
			.max(Double::compare);
		System.out.println(op.get());
		
		Optional<Employee> op2 = emps.stream()
			.min((e1, e2) -> Double.compare(e1.getSalary(), e2.getSalary()));
		
		System.out.println(op2.get());
	}
	
	//注意：流进行了终止操作后，不能再次使用
	@Test
	public void test4(){
		Stream<Employee> stream = emps.stream()
		 .filter((e) -> e.getStatus().equals(Status.FREE));
		
		long count = stream.count();
		
		stream.map(Employee::getSalary)
			.max(Double::compare);
	}
}